package rpc;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;

import java.io.IOException;

/**
 * 作者：吴超
 * 邮箱：wuchao_19931120@163.com
 * 时间：2022-01-04
 * 描述：
 */

// 实现通信接口
public class NNServer implements RPCProtocol{


    @Override
    public void mkdirs(String path) {
        System.out.println("服务端接受到客户端的请求" + path);
    }

    public static void main(String[] args) throws IOException {
        // 启动服务
        RPC.Server server = new RPC.Builder(new Configuration())
                .setBindAddress("localhost")
                .setPort(8888)
                .setProtocol(RPCProtocol.class)
                .setInstance(new NNServer())
                .build();
        System.out.println("服务器开始工作!");
        server.start();
    }
}
